package data.platform.common.service.query;

import data.platform.common.merge.AggregateItem;
import data.platform.common.merge.ArithmeticType;
import reactor.core.publisher.Flux;
import reactor.util.function.Tuple2;

import java.time.LocalDate;
import java.util.Map;
import java.util.Set;

public interface DataAggregateQueryService {

    // key: tagJson
    Flux<Tuple2<String, AggregateItem>> queryAggregateItems(ArithmeticType arithmeticType, String metric, Map<String, Set<String>> tags);
}
